package cc.shacocloud.redis.study.queue.delay;

/**
 * 延时处理消息
 */
public interface DelayMessage extends DelayQueue {

    /**
     * 延迟消息
     *
     * @param msg   消息
     * @param delay 延迟执行时间 单位/ms
     * @return 到期时间，精确到毫秒级时间戳
     */
    long delay(byte[] msg, long delay);

}
